from pymysql import Connection as cc

con = None

try:
    con = cc(
        host='159.138.150.44',
        port=3306,
        user='root',
        password='lgifLZKX86EcInQw',
        database='tianhao',
        autocommit=True
    )
    # 创建游标
    cursors = con.cursor()

    sql = """
        CREATE TABLE `business_msg2` (
          `msg_id` varchar(30) NOT NULL COMMENT '消息ID',
          `b_id` varchar(30) NOT NULL COMMENT '业务Id',
          `msg_type` varchar(12) NOT NULL COMMENT '消息类型 10001 公告，10002 钥匙审核，10003 小区入驻审核，10004 小区添加审核',
          `title` varchar(30) NOT NULL COMMENT '消息标题',
          `url` varchar(100) NOT NULL COMMENT '消息路径',
          `view_type_cd` varchar(100) NOT NULL COMMENT '受众类型，10000 系统内消息，20000 小区内消息， 30000 商户内， 40000 员工ID（userId）',
          `view_obj_id` varchar(64) NOT NULL COMMENT '对象ID',
          `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
          `operate` varchar(4) NOT NULL COMMENT '数据状态，添加ADD，修改MOD 删除DEL'
        ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
"""
    #利用游标执行sql语句
    cursors.execute(sql)

except Exception as e:
    print('异常:', e)
finally:
    if con:
        con.close()
